package com.abyss.inter;

import com.abyss.bean.CleanBean;
import org.apache.flink.streaming.api.datastream.DataStream;

/**
 * @Date 2020/9/16
 * 通用接口
 */
public interface ProcessDataInterface {

    void process(DataStream<CleanBean> waterData);
}
